package com.alibaba.datax.elasticresource.watcher;

import org.apache.flink.runtime.resourceconsumer.ResourceConsumer;

/**
 * @类名: DataxWatcherRunner
 * @说明: 资源消费者runner
 *
 * @author   leehom
 * @Date	 2023年10月26日 上午10:06:20
 * 修改记录：
 *
 * @see 	 
 */
public interface DataxWatcherRunner extends AutoCloseable {

    /**
     * Start the execution of the {@link ResourceConsumer}.
     *
     * @throws Exception if the ResourceConsumer cannot be started
     */
    void startx() throws Exception;

}
